Feature: kafka_consumer_manager


